package cdc.rxjava2.demo;

import io.reactivex.Flowable;
import io.reactivex.functions.Consumer;
public class Hello3 {
	/**
	 * 简写形式
	 */
	public Hello3() {
		Flowable.just("RxJava3 Hello3")
		.subscribe(new Consumer<String>() {
	        @Override
	        public void accept(String s) throws Exception {
	            System.out.println(s);
	        }
	    });
		
		Flowable.just("RxJava3 Hello3 lamdba")  
	    .subscribe(s -> System.out.println(s));
		
		
		Flowable.just("RxJava3 Hello3 lamdba")  
	    .subscribe(s -> System.out.println(s + " -ittianyu"));  
	}

}
